package com.htdata.iiot.kafka2tsdb.config;

import com.htdata.iiot.kafka2tsdb.cmd.Cmd;
import com.htiiot.common.config.ConfigFactory;

public class Configs {
	
	public static final class KafkaConfig{
        public static String GROUP_ID = Cmd.groupId!=null?Cmd.groupId:ConfigFactory.getConfigMgr().get("kafka.consumer","group.id","kafka_")+"dstatus";
        public static final String BOOTSTRAP_SERVERS = ConfigFactory.getConfigMgr().get("kafka.consumer","bootstrap.servers");
        public static String TOPIC = Cmd.topic!=null?Cmd.topic:ConfigFactory.getConfigMgr().get("kafka.consumer","devStatus","cstest");
        public static final String METADATA_BROKERS = ConfigFactory.getConfigMgr().get("kafka.consumer","metadata.broker.list");
        public static final boolean ENABLE_AUTO_COMMIT = true;
        //Boolean.parseBoolean(ConfigFactory.getConfigMgr().get("kafka.consumer","enable.auto.commit"));
        //public static final boolean ENABLE_AUTO_COMMIT = Boolean.parseBoolean(ConfigFactory.getConfigMgr().get("kafka.consumer","enable.auto.commit"));
        public static final String AUTO_OFFSET_RESET = ConfigFactory.getConfigMgr().get("kafka.consumer","auto.offset.reset");
	       
	}
	
	public static final class BaseConfig{

		public static int threads=10;
		public static String url="http://127.0.0.1:4243/api/put?summary";
		public static boolean log= false;
		
	};

}
